package cn.itcast.keyBy;

import cn.itcast.bean.CleanBean;
import org.apache.flink.api.java.functions.KeySelector;

public class KeySelectFunction implements KeySelector<CleanBean,String>{

    @Override
    public String getKey(CleanBean value) throws Exception {
        return value.getSecCode();
    }
}
